package com.qf.ps;

import org.springframework.amqp.rabbit.annotation.RabbitHandler;
import org.springframework.amqp.rabbit.annotation.RabbitListener;
import org.springframework.stereotype.Component;

/**
 * projectName: forth
 *
 * @author: MaTianWei
 * time: 2021/8/2 22:23
 * description:
 */

@RabbitListener(queues = "ps_queue1")
@Component
public class PsQueueListener1 {

    //接收消息处理消息的方法
    @RabbitHandler
    public void messageHandler(String msg) {
        System.out.println("====ps_queue1=====" + msg);
    }
}